const mysql = require("mysql2/promise");

// 配置 MySQL 连接池
const db = mysql.createPool({
    // host: "127.0.0.1", 
    host: "38.22.95.196",// MySQL 服务器地址
    user: "root",  // MySQL 用户名
    password: "1235678", // MySQL 密码
    database: "eswangpan", // 数据库名称
    waitForConnections: true,
    connectionLimit: 10, // 最大连接数
    queueLimit: 0,
});

// 查询数据库的封装函数（使用 async/await）
async function queryDatabase(query, params = []) {
    try {
        const [results] = await db.execute(query, params);
        return results;
    } catch (err) {
        console.error("❌ 数据库查询失败:", err);
        throw err;
    }
}

// 导出
module.exports = { queryDatabase };
